package com.jubull.rule.engine.functions;

import com.jubull.rule.engine.beans.EventBean;
import com.jubull.rule.engine.beans.RuleMatchResult;
import org.apache.flink.streaming.api.functions.KeyedProcessFunction;
import org.apache.flink.util.Collector;

/**
 * @author liuyun
 * @title: RuleMatchKeyedProcessFunction
 * @projectName jubull_marking
 * @description: 规则匹配计算的函数
 *                  规则：
 *                      处罚事件：K事件，事件属性（p2 = v1）
 *                      画像属性条件：tog87 = v2 , tag26 -= v1
 *                      行为次数条件： 2021-06-18 ~ 当前，事件 C【p6 = v8, p12 = v5】做过 >= 2次
 * @date 2022-3-25 01:36
 */

public class RuleMatchKeyedProcessFunction extends KeyedProcessFunction<String, EventBean, RuleMatchResult> {

    @Override
    public void processElement(EventBean eventBean,
                               KeyedProcessFunction<String, EventBean, RuleMatchResult>.Context context,
                               Collector<RuleMatchResult> collector) throws Exception {


    }
}
